package com.zc.common.mq.consumer;

/**
 * <p>Description : </p>
 *
 * @author : xuhongcao
 * @version : v1.0.0
 * @since : 6/4/2022
 **/
public interface ReceiveMessageDao {

    void insert(String messageKey, String topic, String serializable);

    void insert(String messageKey, String topic, String tag, Object body);

    Boolean existByMessageKey(String messageKey);
}
